package com.study;

import org.apache.flink.streaming.api.collector.selector.OutputSelector;
import org.apache.flink.streaming.api.datastream.SplitStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author sjw
 * @description
 * @date 2019-08-20 下午7:08
 */
public class StreamSplit {
    public static void main(String[] args) {
        StreamExecutionEnvironment env=StreamExecutionEnvironment.getExecutionEnvironment();
        SplitStream<Long> splitStream=env.generateSequence(1,11).split(new OutputSelector<Long>() {
            @Override
            public Iterable<String> select(Long aLong) {
                return null;
            }
        });
    }
}
